package org.example.operator.action

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

/**
 *  案例实操
 *
 */
object Spark01_RDD_Operator_Collect {
  def main(args: Array[String]): Unit = {

    val conf: SparkConf = new SparkConf().setMaster("local[*]").setAppName("RDD")
    val context = new SparkContext(conf)

    val rdd: RDD[Int] = context.makeRDD(List(1,2,3,4),2)
    // 采集数据打印
    /** 行动算子
      * 其实就是触发了作业（Job）的提交执行
      * 底层代码调用了环境对象的runJob方法
      * 底层代码中会创建ActionJob，并提交执行
      * collect
      */
    rdd.collect()

    context.stop()
  }
}
